package com.fulu.game.bigdata.realtime.entity

import org.apache.flink.calcite.shaded.com.fasterxml.jackson.databind.{DeserializationFeature, ObjectMapper}

import scala.beans.BeanProperty
import java.util

class Job {

  @BeanProperty var jobName : String = _
  @BeanProperty var sources : util.List[Source] = _
  @BeanProperty var operators : util.List[Operator] = _

}
object Job {

  def apply(json: String): Job = {
    new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false).readValue(json, classOf[Job])
  }

}
